using EasyNetQ.IntegrationTests.Utils;

namespace EasyNetQ.IntegrationTests.Scheduler;

[Collection("RabbitMQ")]
public class When_publish_and_subscribe_with_delay_using_delay_exchange_with_publish_confirms : IDisposable
{
    public When_publish_and_subscribe_with_delay_using_delay_exchange_with_publish_confirms(RabbitMQFixture fixture)
    {
        bus = RabbitHutch.CreateBus(
            $"host={fixture.Host};prefetchCount=1;publisherConfirms=True;timeout=-1",
            c => c.EnableDelayedExchangeScheduler()
        );
    }

    public void Dispose()
    {
        bus.Dispose();
    }

    private const int MessagesCount = 10;

    private readonly SelfHostedBus bus;

    [Fact]
    public async Task Test()
    {
        using var cts = new CancellationTokenSource(TimeSpan.FromSeconds(10));

        var subscriptionId = Guid.NewGuid().ToString();
        var messagesSink = new MessagesSink(MessagesCount);
        var messages = MessagesFactories.Create(MessagesCount);

        using (await bus.PubSub.SubscribeAsync<Message>(subscriptionId, messagesSink.Receive, cts.Token))
        {
            await bus.Scheduler.FuturePublishBatchAsync(messages, TimeSpan.FromSeconds(5), "#", cts.Token);

            await messagesSink.WaitAllReceivedAsync(cts.Token);
            messagesSink.ReceivedMessages.Should().Equal(messages);
        }
    }
}
